670df8fd447f1dc4135952924fd0a519431e739e,src/main/java/com/couchbase/client/dcp/conductor/Conductor.java,Conductor,startStreamForPartition,#number#number#number#number#number#number#,191

Before Change


                        .toObservable();
                }
            })
            .retryWhen(anyOf(NotConnectedException.class)
                .delay(Delay.fixed(200, TimeUnit.MILLISECONDS))
                .doOnRetry(new Action4<Integer, Throwable, Long, TimeUnit>() {
                    @Override
                    public void call(Integer integer, Throwable throwable, Long aLong, TimeUnit timeUnit) {

After Change


                        .toObservable();
                }
            })
            .retryWhen(anyOf(NotConnectedException.class)
                .max(Integer.MAX_VALUE)
                .delay(Delay.fixed(200, TimeUnit.MILLISECONDS))
                .doOnRetry(new Action4<Integer, Throwable, Long, TimeUnit>() {
                    @Override
                    public void call(Integer integer, Throwable throwable, Long aLong, TimeUnit timeUnit) {